package ebj.common.queue.request;

public class ExecutorThread implements Runnable {

    private Object obj;
    private int delay;

    public ExecutorThread(Object obj, int delay) {
        this.obj = obj;
        this.delay = delay;
    }

    public void run() {
        /*
         * 调用 解析查询语句 & druid请求发起程序
         */
        try {
            if (obj != null) {
                System.out.println("运行的线程数"+Thread.activeCount());
                System.out.println(obj.toString());
            }
            Thread.sleep(delay);
        } catch (InterruptedException e) {

        }
    }
}
